package com.haozhen.spark

/**
  * @author haozhen
  * @email haozh@ync1.com
  * @date 2020/12/9  21:52
  */
object Common {

  case class StartMessage(msg:String)

  case class RegisterWorkInfo(id:String,cpu:Int,ram:Int)

  class WorkInfo(var id:String,cpu:Int,ram:Int){
    var lasterHeartBeatTime = System.currentTimeMillis()
  }

  case object RegisteredWorkerInfo

  case object SendHeartBeat

  case class HeartBeat(id:String)

  case object StartTimeoutCheck

  case object RemoveTimeoutWorker
}
